package com.dtwave.lnstreaming.process.function.process;

import com.alibaba.fastjson.JSONObject;
import com.dtwave.lnstreaming.bean.RtDkhtxxb;
import org.apache.flink.api.common.functions.RichFlatMapFunction;
import org.apache.flink.util.Collector;

public class XfaceFlatFunction extends RichFlatMapFunction<JSONObject, RtDkhtxxb> {
    @Override
    public void flatMap(JSONObject jsonObject, Collector<RtDkhtxxb> collector) throws Exception {

        RtDkhtxxb rtDkhtxxb = new RtDkhtxxb();

        rtDkhtxxb.set_ID("a");
        rtDkhtxxb.setWBHTH("a");
        rtDkhtxxb.setDKHTH("a");
        rtDkhtxxb.setBJGHFS("a");
        rtDkhtxxb.setJRKMC("a");

        collector.collect(rtDkhtxxb);
    }
}
